package com.central.scheduler.plugin.task.flink.sql;

import com.central.scheduler.spi.task.AbstractTask;
import com.central.scheduler.spi.task.TaskChannel;
import com.central.scheduler.spi.task.request.TaskRequest;

/**
 * @author Tindy
 * @date 2022/4/13
 * @describe
 */
public class FlinkSqlTaskChannel  implements TaskChannel {

    @Override
    public void cancelApplication(boolean status) {

    }

    @Override
    public AbstractTask createTask(TaskRequest taskRequest) {
        return new FlinkSqlTask(taskRequest);
    }
}
